package com.dongecloud.stream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MyChannel {
     String INPUT = "donge-input";

     String OUTPUT = "donge-output";

     @Output(OUTPUT)
     MessageChannel output();

     @Input(INPUT)
     SubscribableChannel input();
}
